// 创建blog数据库，并创建blog_user表，连接数据库
let mysql = require('mysql');
let connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: '123',
    database: 'blog'
});
connection.connect();
// 定义用户模块的处理注册新用户的model函数
module.exports = {
    // 定义一个根据username查找数据的函数
    getUserByName: (username, cb) => {
        let sql = 'select * from users where username=?';
        connection.query(sql, [username], (err, results) => {
            if (err) return cb(err, null);
            cb(null, results);
        })
    },

    addNewUser: (newuser, cb) => {
        let sql = 'insert into users set ?';
        connection.query(sql, newuser, (err, results) => {
            if (err) return cb(err, null);
            cb(null, results);
        })
    },

    // 定义登录的函数，需要利用用户信息查询，所以需要传参
    checkLogin: (user, cb) => {
        // 写sql语句，操作数据库
        let sql = 'select * from users where username=? and password=?';
        connection.query(sql, [user.username, user.password], (err, results) => {
            if (err) return cb(err, null);
            cb(null, results);
        });
    }
};